package commom

type ChannelInboundHandler func(c *ChannelProcess)

type ChannelProcess struct {
	ctx        *ChannelContext
	DecodeData interface{} //解码后的数据
}

//发送数据到编码处理器
func (p *ChannelProcess) WriteAndFlush(t interface{}) {
	encode := &EncodeCtx{
		ctx:  p.ctx,
		Data: t,
	}
	p.ctx.EncodeH(encode)
}
